package com.gss.plugin.kafka.handle;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.stereotype.Service;

/**
 * @author: DYang
 * @since: 2023/8/24
 * @description:
 */
@ConditionalOnMissingBean(ConsumerHandle.class)
@Service
public class DefaultConsumerHandle implements ConsumerHandle{

    /**
     * 处理数据
     * @param record
     * @return
     */
    @Override
    public boolean handle(ConsumerRecord<String, String> record){
        return true;
    }
}
